package com.doit.day01;

import redis.clients.jedis.Jedis;

import java.util.UUID;

/**
 * 需求：任务调度系统：生产者不断产生任务，放入task-queue排队
 * 消费者不断拿出任务来处理，同时放入一个tmp-queue暂存，如果任务处理成功，则清除tmp-queue，否则，将任务弹回task-queue
 */
public class ProducerDemo {
    public static void main(String[] args) throws InterruptedException {
        //redis对象
        Jedis redis = new Jedis("linux01", 6379);

        System.out.println("年薪百万的39期的程序员们，开始生产有bug的代码了！");

        while (true){
            UUID uuid = UUID.randomUUID();

            //要干什么事情==》 放在redis的list里面
            redis.lpush("producer",uuid.toString());
            //让他睡一会
            Thread.sleep(2000);
            if (redis.llen("producer")>=10){
                //让他睡一会
                Thread.sleep(5000);
            }
        }



    }
}
